package cn.dataling.dag.listener;

import cn.dataling.dag.pojo.DagWorkflow;

/**
 * dag工作流监听器
 */
public interface DagWorkflowListener {
    /**
     * 工作流开始
     */
    void onStart(DagWorkflow dagWorkflow);

    /**
     * 工作流完成
     */
    void onCompleted(DagWorkflow dagWorkflow);

    /**
     * 工作流暂停
     */
    void onPaused(DagWorkflow workflow);

    /**
     * 工作流恢复
     */
    void onProceed(DagWorkflow dagWorkflow);
}
